/*
 * Singularity Engine
 * Copyright (C) 2010 Vyacheslav Vorobyov, All rights reserved.
 * See LICENSE for full license information.
 */

/**
 * 
 */
package org.singularity.mapred.model;

import org.singularity.mapred.Destination;
import org.singularity.mapred.MapFun;
import org.singularity.mapred.Source;

/**
 * @author vjache
 *
 */
public class MapFlow<VT0, KT1, VT1> extends Flow {

	private final MapFun<VT0, KT1, VT1> _fun;

	/**
	 * @param aCascade
	 * @param aSource
	 * @param aDestination
	 */
	public MapFlow(Object aId,DefaultCascade aCascade, Source aSource,
			Destination aDestination, MapFun<VT0, KT1, VT1> aMapFun) {
		super(Code.MapFlow, aId, aCascade, aSource, aDestination);
		_fun = aMapFun;
	}

	/**
	 * @return the fun
	 */
	public MapFun<VT0, KT1, VT1> getMapFun() {
		return _fun;
	}

}
